package main

func main() {
	//_ = logconfig.InitializeLog()
	//test.CreatTopicTest("hot_patch", 6, 3)
	//test.ChangePartitionTest("first_topic", 5)
	//test.DeleteTopicTest("first_topic")
	//test.DeleteTopicTest("__consumer_offsets")
	//service.StartKafkaMess()
	//go func() {
	//	for i := 0; i < 15; i++ {
	//		time.Sleep(1 * time.Second)
	//		logger.Infof("============ sleep kafka time is %d", 14-i)
	//	}
	// service.StopKafkaMess()
	//}()
	//var s = make(chan struct{})
	//s <- struct{}{}
	//test.RegisterTest(100)
	//var s = make(chan struct{})
	//s <- struct{}{}
	//test.CreatTopicTest("hotpatch", 9, 3)
	//test.DeleteTopicTest("hotpatch")
	//health.CheckReady()
}
